package org.budo.dubbo.protocol.async.util;

import org.budo.dubbo.protocol.async.repository.AsyncRepository;

import com.alibaba.dubbo.common.URL;
import com.alibaba.dubbo.rpc.Invoker;

/**
 * @author lmw
 */
public class RepositoryUtil {
    public static String getAsyncRepositoryBeanName(Invoker<?> invoker) {
        URL url = invoker.getUrl();
        return url.getParameter(AsyncRepository.ASYNC_REPOSITORY_BEAN_NAME);
    }
}